package com.tanhua.server.service;

import com.tanhua.server.utils.UserHolder;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.HashMap;
import java.util.Map;

@Service
public class MovementsMqService {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;


    public void sendMsg(String movementId,Integer type){
//        1、当前登录人  2、圈子id   3、什么操作
        Long userId = UserHolder.getUserId();
        Map map = new HashMap();
        map.put("userId",userId);
        map.put("movementId",movementId);
        map.put("type",type);
        rocketMQTemplate.convertAndSend("recommend_quanzi_logs",map);
        System.out.println("已经发送了对圈子操作的日志数据");

    }

//    - 操作1： 浏览 +1
//    - 操作2： 点赞 +5
//    - 操作3： 喜欢 +8
//    - 操作4： 评论 + 10
//    - 操作5：取消点赞 -5
//    - 操作6：取消喜欢 -8


}
